#include <iostream>
#include "krpc/subcribe_asio.h"

struct hehe
{
	int a;
	int b;
	MSGPACK_DEFINE(a,b);

};

int main(int argc, char const *argv[])
{
	asio::io_context ioctx;
	KRPC::LOCALSTREAM_ASIO com(ioctx, "unix");
	KRPC::SubcribeByAsio<std::string, int> sub("sub", com, 3000);
	sub.start([](std::string str, int i){
		std::cout << "str: " << str << ", i: " << i << std::endl;
	});
	ioctx.run();
	return 0;
}
